const mysql = require('mysql')

//创建连接池
const pool = mysql.createPool ({
    //IP地址
    host: 'localhost',
    //端口号
    port: 3306,
    //数据库
    database: 'koa',
    //用户名
    user: 'root',
    //密码
    password: 'asdf'
})

//对数据进行增删改查的基础操作
function query(sql, callback) {
    //连接数据库
    pool.getConnection(function(err, connection){
        //连接成功后
        connection.query(sql, function(err, rows) {
            //通过回调函数返回查询结果
            callback(err, rows)

            //断开数据库连接
            connection.release()
        }) 
    })
}

//导出方法
module.exports = {
    query,
}